package cn.wenhaha.app.job.core;

import cn.wenhaha.app.mapping.bean.dto.FieldObj;
import cn.wenhaha.app.mapping.bean.dto.MappingObj;
import cn.wenhaha.app.mapping.bean.dto.WriteObj;
import cn.wenhaha.sync.core.DataSyncCoreContext;
import lombok.Data;

import java.util.List;

/**
 * 数据源
 * --------
 *
 * @author ：wyndem
 * @Date ：Created in 2022-11-30 22:53
 */
@Data
public class DataSource {

    private  Integer sourceId;
    private String sourceObj;
    private String code;

    /**
     * 同步核心上下文
     **/
    private DataSyncCoreContext syncCoreContext;

    /** 映射关联字段 **/
    private List<MappingObj> source;

    /** 同步条件 **/
    private List<FieldObj> condition;

    /** 同步回写成功 **/
    private   List<WriteObj> writesSuccess;
    /** 回写失败 **/
    private   List<WriteObj> writesFail;


}
